package com.handl.springcloud.amqp.consumer;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.SubscribableChannel;

/**
 * Created by handl on 2017/11/12.
 *
 * 对应SendToReceiver的通道
 *
 *
 *
 */
public interface SendToBinder {
    /**
     * 消费者用来输入的通道，默认为通道的名称
     *
     */
    String INPUT = "consumer_get";
    /**
     * 消费者用来输出的通道，默认为通道的名称
     */
    String OUTPUT = "producer_get";

    /**
     *通过@Output注解绑定了一个名为“producer_get”的输出通道
     * @return
     */
    @Output(OUTPUT)
    SubscribableChannel producer_get_server();

    /**通过@Input注解绑定了一个名为“consumer_get”的输入通道
     *
     * @return
     */
    @Input(INPUT)
    SubscribableChannel consumer_get_server();
}
